package cuiyt.juc.bq;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author cyt
 * @create 2020-09-16 下午 3:08
 */
public class demo3 {
    /**
     * 阻塞队列
     * <p>
     * 一直等待阻塞
     *
     * @param args
     */
    public static void main(String[] args) throws InterruptedException {
        ArrayBlockingQueue<Object> queue = new ArrayBlockingQueue<>(3);
        queue.put(1);
        queue.put(1);
        queue.put(1);
        /**
         * 此时会一直阻塞
         */
//        queue.put(1);
        queue.take();
        queue.take();
        queue.take();
        /**
         * 此时会一直阻塞
         */
        queue.take();
    }
}
